package com.learning.rocketmq.demo;

import org.apache.rocketmq.common.message.MessageExt;

import java.util.List;

/**
 * 消息队列-消息消费处理接口
 */
public interface MQMsgProcessor {
    /**
     * 消息队列-统一消息消费处理接口
     * MQ消息处理
     * 如果没有return true ，consumer会重新消费该消息，直到return true
     *
     * @param topic 消息主题
     * @param tag   消息标签
     * @param msgs  消息
     * @return
     */
    MQConsumeResult handle(String topic, String tag, List<MessageExt> msgs);
}